import time
import random
import multiprocessing

# 2）使用 Queue 通信
# 间隔随机时间向queue中放入随机数
def func1(queue):
     for i in range(5):
          queue.put(i)
          print(i)
          time.sleep(2)

# 从queue中取出数据
def func2(queue):
     for i in range(5):
          print(queue.get())

if __name__ == "__main__":
     queue = multiprocessing.Queue()
     p1 = multiprocessing.Process(target=func1, args=(queue,))
     p2 = multiprocessing.Process(target=func2, args=(queue,))
     p1.start()
     p2.start()
     p1.join()
     p2.join()